﻿using System.Collections.Concurrent;
using HelenServer.FileStorage.Contracts;

namespace HelenServer.FileStorage.Services;

[Injection(typeof(IFileStorateMigrateQueueProvider), ServiceLifetime.Singleton)]
internal class FileStorageMigrateQueueProvider : IFileStorateMigrateQueueProvider
{
    private readonly ConcurrentQueue<KeyValuePair<int, IEnumerable<NotifySpiderModel>>> _queue;

    public ConcurrentQueue<KeyValuePair<int, IEnumerable<NotifySpiderModel>>> Queue => _queue;

    public FileStorageMigrateQueueProvider()
    {
        _queue = new();
    }
}